const Controller = require('../common-core/base');

// 定义创建接口的请求参数规则
// const createRule = {
//   accesstoken: 'string',
//   title: 'string',
//   tab: { type: 'enum', values: [ 'ask', 'share', 'job' ], required: false },
//   content: 'string',
// };

class AdController extends Controller {
  async show() {
    const ctx = this.ctx;
    // 校验 `ctx.request.body` 是否符合我们预期的格式
    // 如果参数校验未通过，将会抛出一个 status = 422 的异常
    //ctx.validate(createRule, ctx.request.body);
    // 调用 service 创建一个 topic

    const adId = ctx.params.id;
    console.log('AdController show');
    console.log(adId);

    const adInfo = await ctx.service.ad.find(adId);
    console.log(adInfo);
    if(adInfo == ''){
      this.Error(1234,'查询不到数据');
    }
    this.Success(adInfo);
  }

  async insert() {
    const { ctx, service } = this;

    const result = await this.app.mysql.get('weshop').beginTransactionScope(async dao => {
      const res = await dao.insert('ad', { id: 'djp1',url: ctx.query.url });
      if(res.affectedRows !== 1) {
        this.Error('插入失败');
      }
      return res.affectedRows
    }, ctx);
    this.Success(result);
    
  }
}
module.exports = AdController;